package com.sola.rabbitmq.send.service;

import java.util.Date;

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**   
 * 
 * @Package: com.sola.rabbitmq.send.service 
 * @author: kangxiaohui   
 * @date: 2017年8月20日 上午10:19:56 
 *
 */
@Component
public class SenderService {

	//通过模板接收发送消息
	@Autowired
	private AmqpTemplate template;
	
	public void send(){
		template.convertAndSend("queue", "this is a test,I'm sola");//queue 要和 return new Queue("queue"); 一致
	}
	
	public void sendUser(){
		com.sola.rabbitmq.send.entity.User user = new com.sola.rabbitmq.send.entity.User();
		user.setAddress("广东");
		user.setBirthday(new Date());
		user.setId("1231310112");
		user.setName("sola");
		user.setPassword("123456");
		template.convertAndSend("queue", user);//queue 要和 return new Queue("queue"); 一致
	}
}
